package cn.lsh.kafka.serializer;

import cn.lsh.kafka.db.entity.OffsetEntity;
import org.apache.kafka.common.serialization.Serializer;

public class OffsetSerializer implements Serializer<OffsetEntity> {
	@Override
	public byte[] serialize(String topic, OffsetEntity offsetEntity) {
		return offsetEntity.toString().getBytes();
	}
}
